🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / app / src / test / java / com / geeksville / mesh / repository / radio / NordicBleInterfaceRetryTest.kt
Displaying Raw • Download
app/src/test/java/com/geeksville/mesh/repository/radio/NordicBleInterfaceRetryTest.kt features/lockdown (1ea87dbb) Text, 12.09 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787com.geeksville.mesh.repository.radio
Tff7b72import T7ee787co.touchlab.kermit.Logger
Tff7b72import T7ee787co.touchlab.kermit.Severity
Tff7b72import T7ee787io.mockk.clearMocks
Tff7b72import T7ee787io.mockk.mockk
Tff7b72import T7ee787io.mockk.verify
Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi
Tff7b72import T7ee787kotlinx.coroutines.delay
Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.android.CentralManager
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.android.mock.mock
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.ConnectionResult
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.PeripheralSpec
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.PeripheralSpecEventHandler
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.Proximity
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.ReadResponse
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.client.mock.internal.MockRemoteCharacteristic
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.CharacteristicProperty
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.LegacyAdvertisingSetParameters
Tff7b72import T7ee787no.nordicsemi.kotlin.ble.core.Permission
Tff7b72import T7ee787org.junit.Before
Tff7b72import T7ee787org.junit.Test
Tff7b72import T7ee787java.util.UUID
Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds
Tff7b72import T7ee787kotlin.uuid.ExperimentalUuidApi
Tff7b72import T7ee787kotlin.uuid.Uuid
Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4, Te6edf3ExperimentalUuidApiTff7b72::Te6edf3classTb4b4b4)
Tff7b72class T56d364NordicBleInterfaceRetryTest Tb4b4b4{
Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff00:11:22:33:44:55Ta5d6ff"
Tff7b72private Tff7b72fun Te6edf3UUIDTb4b4b4.Td2a8fftoKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3Uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3parseTb4b4b4(Tff7b72thisTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4)
Tf0883e@Before
Tff7b72fun Td2a8ffsetupTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3setLogWritersTb4b4b4(
Tff7b72object Tb4b4b4: T56d364coTb4b4b4.Te6edf3touchlabTb4b4b4.Te6edf3kermitTb4b4b4.Te6edf3LogWriterTb4b4b4(Tb4b4b4) Tb4b4b4{
Tff7b72override Tff7b72fun Td2a8fflogTb4b4b4(Te6edf3severityTb4b4b4: Te6edf3SeverityTb4b4b4, Te6edf3messageTb4b4b4: Tffa657StringTb4b4b4, Te6edf3tagTb4b4b4: Tffa657StringTb4b4b4, Te6edf3throwableTb4b4b4: Te6edf3Throwable?Tb4b4b4) Tb4b4b4{
Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ff[Tffd700$Te6edf3severityTa5d6ff] Tffd700$Te6edf3tagTa5d6ff: Tffd700$Te6edf3messageTa5d6ff"Tb4b4b4)
Te6edf3throwableTff7b72?.Te6edf3printStackTraceTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`write succeeds after one retry`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3centralManager Tff7b72= Te6edf3CentralManagerTb4b4b4.Te6edf3FactoryTb4b4b4.Te6edf3mockTb4b4b4(Te6edf3scope Tff7b72= Te6edf3backgroundScopeTb4b4b4)
Tff7b72val Te6edf3service Tff7b72= Te6edf3mockkTff7b72<Te6edf3RadioInterfaceServiceTff7b72>Tb4b4b4(Te6edf3relaxed Tff7b72= Tff7b72trueTb4b4b4)
Tff7b72var Te6edf3toRadioHandleTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff1
Tff7b72var Te6edf3writeAttempts Tff7b72= T79c0ff0
Tff7b72var Te6edf3writtenValueTb4b4b4: Te6edf3ByteArray? Tff7b72= Tff7b72null
Tff7b72val Te6edf3eventHandler Tff7b72=
Tff7b72object Tb4b4b4: T56d364PeripheralSpecEventHandler Tb4b4b4{
Tff7b72override Tff7b72fun Td2a8ffonConnectionRequestTb4b4b4(
Te6edf3preferredPhyTb4b4b4: Te6edf3ListTff7b72<Te6edf3noTb4b4b4.Te6edf3nordicsemiTb4b4b4.Te6edf3kotlinTb4b4b4.Te6edf3bleTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3PhyTff7b72>Tb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3ConnectionResult Tff7b72= Te6edf3ConnectionResultTb4b4b4.Te6edf3Accept
Tff7b72override Tff7b72fun Td2a8ffonWriteCommandTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4, Te6edf3valueTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3characteristicTb4b4b4.Te6edf3instanceId Tff7b72=Tff7b72= Te6edf3toRadioHandleTb4b4b4) Tb4b4b4{
Te6edf3writeAttemptsTff7b72+Tff7b72+
Tff7b72if Tb4b4b4(Te6edf3writeAttempts Tff7b72=Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{
Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffSimulating first write failureTa5d6ff"Tb4b4b4)
Tff7b72throw Te6edf3RuntimeExceptionTb4b4b4(Ta5d6ff"Ta5d6ffTemporary failureTa5d6ff"Tb4b4b4)
Tb4b4b4}
Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffSecond write attempt succeedingTa5d6ff"Tb4b4b4)
Te6edf3writtenValue Tff7b72= Te6edf3value
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffonReadRequestTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4)Tb4b4b4: Te6edf3ReadResponse Tff7b72=
Te6edf3ReadResponseTb4b4b4.Te6edf3SuccessTb4b4b4(Te6edf3byteArrayOfTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72val Te6edf3peripheralSpec Tff7b72=
Te6edf3PeripheralSpecTb4b4b4.Te6edf3simulatePeripheralTb4b4b4(Te6edf3identifier Tff7b72= Te6edf3addressTb4b4b4, Te6edf3proximity Tff7b72= Te6edf3ProximityTb4b4b4.Te6edf3IMMEDIATETb4b4b4) Tb4b4b4{
Te6edf3advertisingTb4b4b4(
Te6edf3parameters Tff7b72= Te6edf3LegacyAdvertisingSetParametersTb4b4b4(Te6edf3connectable Tff7b72= Tff7b72trueTb4b4b4, Te6edf3interval Tff7b72= T79c0ff1T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)Tb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3CompleteLocalNameTb4b4b4(Ta5d6ff"Ta5d6ffMeshtastic_RetryTa5d6ff"Tb4b4b4)
Tb4b4b4}
Te6edf3connectableTb4b4b4(
Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffMeshtastic_RetryTa5d6ff"Tb4b4b4,
Te6edf3isBonded Tff7b72= Tff7b72trueTb4b4b4,
Te6edf3eventHandler Tff7b72= Te6edf3eventHandlerTb4b4b4,
Te6edf3cachedServices Tff7b72= Tb4b4b4{
Te6edf3ServiceTb4b4b4(Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_SERVICE_UUIDTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3toRadioHandle Tff7b72=
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_TORADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72=
Te6edf3setOfTb4b4b4(
Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITETb4b4b4,
Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITE_WITHOUT_RESPONSETb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3WRITETb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMNUM_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3READTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_LOGRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Te6edf3centralManagerTb4b4b4.Te6edf3simulatePeripheralsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3peripheralSpecTb4b4b4)Tb4b4b4)
Te6edf3delayTb4b4b4(T79c0ff1T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Tff7b72val Te6edf3nordicInterface Tff7b72=
Te6edf3NordicBleInterfaceTb4b4b4(
Te6edf3serviceScope Tff7b72= Tff7b72thisTb4b4b4,
Te6edf3centralManager Tff7b72= Te6edf3centralManagerTb4b4b4,
Te6edf3service Tff7b72= Te6edf3serviceTb4b4b4,
Te6edf3address Tff7b72= Te6edf3addressTb4b4b4,
Tb4b4b4)
T8b949e// Wait for connection and stable state
Te6edf3delayTb4b4b4(T79c0ff2T79c0ff0T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4) Tb4b4b4}
T8b949e// Clear initial discovery errors if any (sometimes mock emits empty list initially)
Te6edf3clearMocksTb4b4b4(Te6edf3serviceTb4b4b4, Te6edf3answers Tff7b72= Tff7b72falseTb4b4b4, Te6edf3recordedCalls Tff7b72= Tff7b72trueTb4b4b4)
T8b949e// Test writing
Tff7b72val Te6edf3dataToSend Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x01Tb4b4b4, T79c0ff0Te6edf3x02Tb4b4b4, T79c0ff0Te6edf3x03Tb4b4b4)
Te6edf3nordicInterfaceTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3dataToSendTb4b4b4)
T8b949e// Give it time to process retries (500ms delay per retry in code)
Te6edf3delayTb4b4b4(T79c0ff1T79c0ff5T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Te6edf3assertTb4b4b4(Te6edf3writeAttempts Tff7b72=Tff7b72= T79c0ff2Tb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffShould have attempted write twice, but was Tffd700$Te6edf3writeAttemptsTa5d6ff" Tb4b4b4}
Te6edf3assertTb4b4b4(Te6edf3writtenValue Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffValue should have been eventually writtenTa5d6ff" Tb4b4b4}
Te6edf3assertTb4b4b4(Te6edf3writtenValueTff7b72!!Tb4b4b4.Te6edf3contentEqualsTb4b4b4(Te6edf3dataToSendTb4b4b4)Tb4b4b4)
T8b949e// Verify we didn't disconnect due to the retryable error
Te6edf3verifyTb4b4b4(Te6edf3exactly Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3anyTff7b72<Te6edf3BleErrorTb4b4b4.Te6edf3BluetoothErrorTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3nordicInterfaceTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`write fails after max retries`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3uniqueAddress Tff7b72= Ta5d6ff"Ta5d6ff11:22:33:44:55:66Ta5d6ff"
Tff7b72val Te6edf3centralManager Tff7b72= Te6edf3CentralManagerTb4b4b4.Te6edf3FactoryTb4b4b4.Te6edf3mockTb4b4b4(Te6edf3scope Tff7b72= Te6edf3backgroundScopeTb4b4b4)
Tff7b72val Te6edf3service Tff7b72= Te6edf3mockkTff7b72<Te6edf3RadioInterfaceServiceTff7b72>Tb4b4b4(Te6edf3relaxed Tff7b72= Tff7b72trueTb4b4b4)
Tff7b72var Te6edf3toRadioHandleTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff1
Tff7b72var Te6edf3writeAttempts Tff7b72= T79c0ff0
Tff7b72val Te6edf3eventHandler Tff7b72=
Tff7b72object Tb4b4b4: T56d364PeripheralSpecEventHandler Tb4b4b4{
Tff7b72override Tff7b72fun Td2a8ffonConnectionRequestTb4b4b4(
Te6edf3preferredPhyTb4b4b4: Te6edf3ListTff7b72<Te6edf3noTb4b4b4.Te6edf3nordicsemiTb4b4b4.Te6edf3kotlinTb4b4b4.Te6edf3bleTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3PhyTff7b72>Tb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3ConnectionResult Tff7b72= Te6edf3ConnectionResultTb4b4b4.Te6edf3Accept
Tff7b72override Tff7b72fun Td2a8ffonWriteCommandTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4, Te6edf3valueTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3characteristicTb4b4b4.Te6edf3instanceId Tff7b72=Tff7b72= Te6edf3toRadioHandleTb4b4b4) Tb4b4b4{
Te6edf3writeAttemptsTff7b72+Tff7b72+
Te6edf3printlnTb4b4b4(Ta5d6ff"Ta5d6ffSimulating write failure #Tffd700$Te6edf3writeAttemptsTa5d6ff"Tb4b4b4)
Tff7b72throw Te6edf3RuntimeExceptionTb4b4b4(Ta5d6ff"Ta5d6ffPersistent failureTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffonReadRequestTb4b4b4(Te6edf3characteristicTb4b4b4: Te6edf3MockRemoteCharacteristicTb4b4b4)Tb4b4b4: Te6edf3ReadResponse Tff7b72=
Te6edf3ReadResponseTb4b4b4.Te6edf3SuccessTb4b4b4(Te6edf3byteArrayOfTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72val Te6edf3peripheralSpec Tff7b72=
Te6edf3PeripheralSpecTb4b4b4.Te6edf3simulatePeripheralTb4b4b4(Te6edf3identifier Tff7b72= Te6edf3uniqueAddressTb4b4b4, Te6edf3proximity Tff7b72= Te6edf3ProximityTb4b4b4.Te6edf3IMMEDIATETb4b4b4) Tb4b4b4{
Te6edf3advertisingTb4b4b4(
Te6edf3parameters Tff7b72= Te6edf3LegacyAdvertisingSetParametersTb4b4b4(Te6edf3connectable Tff7b72= Tff7b72trueTb4b4b4, Te6edf3interval Tff7b72= T79c0ff1T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)Tb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3CompleteLocalNameTb4b4b4(Ta5d6ff"Ta5d6ffMeshtastic_FailTa5d6ff"Tb4b4b4)
Tb4b4b4}
Te6edf3connectableTb4b4b4(
Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffMeshtastic_FailTa5d6ff"Tb4b4b4,
Te6edf3isBonded Tff7b72= Tff7b72trueTb4b4b4,
Te6edf3eventHandler Tff7b72= Te6edf3eventHandlerTb4b4b4,
Te6edf3cachedServices Tff7b72= Tb4b4b4{
Te6edf3ServiceTb4b4b4(Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_SERVICE_UUIDTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3toRadioHandle Tff7b72=
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_TORADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72=
Te6edf3setOfTb4b4b4(
Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITETb4b4b4,
Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3WRITE_WITHOUT_RESPONSETb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3WRITETb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMNUM_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_FROMRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3READTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Te6edf3CharacteristicTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3BleConstantsTb4b4b4.Te6edf3BTM_LOGRADIO_CHARACTERTb4b4b4.Te6edf3toKotlinUuidTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3properties Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3CharacteristicPropertyTb4b4b4.Te6edf3NOTIFYTb4b4b4)Tb4b4b4,
Te6edf3permission Tff7b72= Te6edf3PermissionTb4b4b4.Te6edf3READTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Te6edf3centralManagerTb4b4b4.Te6edf3simulatePeripheralsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3peripheralSpecTb4b4b4)Tb4b4b4)
Te6edf3delayTb4b4b4(T79c0ff1T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Tff7b72val Te6edf3nordicInterface Tff7b72=
Te6edf3NordicBleInterfaceTb4b4b4(
Te6edf3serviceScope Tff7b72= Tff7b72thisTb4b4b4,
Te6edf3centralManager Tff7b72= Te6edf3centralManagerTb4b4b4,
Te6edf3service Tff7b72= Te6edf3serviceTb4b4b4,
Te6edf3address Tff7b72= Te6edf3uniqueAddressTb4b4b4,
Tb4b4b4)
T8b949e// Wait for connection
Te6edf3delayTb4b4b4(T79c0ff2T79c0ff0T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3timeout Tff7b72= T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3onConnectTb4b4b4(Tb4b4b4) Tb4b4b4}
T8b949e// Clear initial discovery errors
Te6edf3clearMocksTb4b4b4(Te6edf3serviceTb4b4b4, Te6edf3answers Tff7b72= Tff7b72falseTb4b4b4, Te6edf3recordedCalls Tff7b72= Tff7b72trueTb4b4b4)
T8b949e// Trigger write which will fail repeatedly
Te6edf3nordicInterfaceTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x01Tb4b4b4)Tb4b4b4)
T8b949e// Wait for all 3 attempts + delays (500ms * 2)
Te6edf3delayTb4b4b4(T79c0ff2T79c0ff5T79c0ff0T79c0ff0.Te6edf3millisecondsTb4b4b4)
Te6edf3assertTb4b4b4(Te6edf3writeAttempts Tff7b72=Tff7b72= T79c0ff3Tb4b4b4) Tb4b4b4{
Ta5d6ff"Ta5d6ffShould have attempted write 3 times (initial + 2 retries), but was Tffd700$Te6edf3writeAttemptsTa5d6ff"
Tb4b4b4}
T8b949e// Verify onDisconnect was called after retries exhausted
T8b949e// Nordic BLE wraps RuntimeException in BluetoothException
Te6edf3verify Tb4b4b4{ Te6edf3serviceTb4b4b4.Te6edf3onDisconnectTb4b4b4(Te6edf3anyTff7b72<Te6edf3BleErrorTb4b4b4.Te6edf3BluetoothErrorTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3nordicInterfaceTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.16s